package com.love.cloud.common.redis.queue.listener;

import org.springframework.data.redis.connection.stream.MapRecord;

/**
 * 统一消费者回调
 * @author hongdongqu
 */
public interface ConsumerListener {
    /**
     * 消费者消费消息
     * @param message
     */
    void onMessage(MapRecord<String, String, String> message);
}
